package com.sun.clients.service;

import org.apache.kafka.clients.consumer.ConsumerRecords;

public interface MessageService {

    void saveMessage(ConsumerRecords<String, String> records);

}
